import sqlite3
import os


def check_and_init_db(db_name="local_db.sqlite"):
    # Проверяет существование БД и инициализирует её при необходимости
    if not os.path.exists(db_name):
        from db_init import db_init
        db_init(db_name)


def execute_query(db_name, query):
    # Подключается к БД, выполняет запрос и возвращает результаты
    check_and_init_db(db_name)

    with sqlite3.connect(db_name) as conn:
        cursor = conn.cursor()
        cursor.execute(query)
        results = cursor.fetchall()
    return results
